package profile.dsplog

import org.apache.spark.sql.SparkSession

/**
  * Created by hunter.coder 涛哥  
  * 2019/4/16 15:08
  * 交流qq:657270652
  * Version: 1.0
  * 更多学习资料：https://blog.csdn.net/coderblack/
  * Description:
  **/
object DspIdMapping {

  def main(args: Array[String]): Unit = {

    val spark = SparkSession.builder().appName("xx").master("local[*]").getOrCreate()

    val df = spark.read.parquet("G:\\sharkdata\\dsppreout")

    df.show(10,false)

    val idsFrame = df.select("imei","idfa","openudid","androidid")

    idsFrame.show(10,false)

    // ID-MAPPING  逻辑开发

    spark.close()
  }

}
